from datetime import timedelta
from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor

jms_dwd__dwd_dependent_hi_dwd_wide_yl_rt_ssmx_bill_detail_hf_02 = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="dwd_dependent_hi_dwd_wide_yl_rt_ssmx_bill_detail_hf_02",
    filepath='/dw/hive/jms_dim.db/external/dim_dependent/dt={{ execution_date | cst_hour }}/dep=dwd_wide_yl_rt_ssmx_bill_detail_hf',
    execution_timeout=timedelta(hours=1),
    email=['macheng@jtexpress.com','yl_bigdata@yl-scm.com'],
    retries=1,
)
